package org.rcy.framework.mq.converter;

import org.apache.rocketmq.spring.support.RocketMQMessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author 吴康桥
 * @Description
 * @date 2022/11/17 14:46
 */

@Configuration
public class MessageConverterConfiguration {
	public MessageConverterConfiguration() {
	}


	@Bean
	public RocketMQMessageConverter createRocketMQMessageConverter() {
		return new RocketMQMessageConverter();
	}

	@Bean
	public RabbitMqMessageConverter createRabbitMqMessageConverter() {
		return new RabbitMqMessageConverter();
	}
}
